<?php

// 参考：http://www.php.net/manual/zh/pdo.connections.php
// https://segmentfault.com/a/1190000004106175

include_once 'db_config.php';
try {
// array(PDO::ATTR_PERSISTENT => true) 开启持久化连接
    $dbh = new PDO('mysql:host=localhost;dbname=wx', $db['user'], $db['pwd'], array(PDO::ATTR_PERSISTENT => true));
// 获取请求的类型
    if (!empty($_POST['num'])) {
        $sql = 'SELECT * from usercumulate limit ' . $_POST['num'];
    } else {
        $sql = 'SELECT * from usercumulate';
    }
    foreach ($dbh->query($sql) as $row) {
        $arr['ref_date'][] = $row['ref_date'];
        $arr['cumulate_user'][] = $row['cumulate_user'];
    }
// 把数据转换成json格式
    $data = json_encode($arr);
//var_dump($data);
// 把获取的数据生成json文件
    file_put_contents('usercumulate_' . date('Y-m-d') . '.json', $data);
//echo $data;
// 现在运行完成，在此关闭连接
    $dbh = null;
} catch (PDOException $e) {
    print "Error!: " . $e->getMessage() . "<br/>";
    die();
}
?>